package com.example.mq.common;

import com.example.mq.server.core.BasicProperties;

import java.io.IOException;


@FunctionalInterface
public interface Consumer {
    /**
     * Delivery的意思是投递 这个方法预期在每次服务器收到消息的时候调用
     * 通过这个方法把消息推送给对应的消费者
     * (参考rabbitMq)
     * @param consumerTag
     * @param basicProperties
     * @param body
     */
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
